package com.lianjia.sh.se;

import com.lianjia.sh.se.kafka.client.AbstractKafkaSender;
import com.lianjia.sh.se.kafka.client.annotion.KafkaSender;
import org.springframework.stereotype.Component;

/**
 * Created by yangsp1 on 16/7/28.
 */
@Component
@KafkaSender(topic = "my-topic",bootstrapServers = "10.8.1.160:19092,10.8.1.93:19092")
public class MyKafkaSender extends AbstractKafkaSender {

}
